package com.qdlc.p2p.biz.sms;

import kafka.utils.VerifiableProperties;

import org.apache.commons.lang3.SerializationUtils;

import com.qdlc.p2p.common.core.queue.ValueEvent;

/**
 * Created by wuaj on 2016/4/13.
 */
public class ValueEventEncoder implements kafka.serializer.Encoder<ValueEvent> {
	
	public ValueEventEncoder(){}
	
	public ValueEventEncoder(VerifiableProperties props) {}
	 
    @Override
    public byte[] toBytes(ValueEvent valueEvent) {
        return SerializationUtils.serialize(valueEvent);
    }
}